03fe0cf7d3238103e4f3472d7435da112f6840c2,graylog2-shared/src/main/java/org/graylog2/shared/buffers/processors/ProcessBufferProcessor.java,ProcessBufferProcessor,onEvent,#MessageEvent#number#boolean#,67

Before Change


        }

        LOG.debug("Finished processing message <{}>. Writing to output buffer.", msg.getId());
        handleMessage(msg);

        outgoingMessages.mark();
        tcx.stop();

After Change



        try {
            LOG.debug("Finished processing message <{}>. Writing to output buffer.", msg.getId());
            handleMessage(msg);
        } catch (Exception e) {
            LOG.warn("Unable to process message <{}>: {}", msg.getId(), e);
        } finally {